package com.tongcao.cn.mq.handle;

import com.tongcao.cn.mq.to.AsyncMsg;
import lombok.Data;

/**
 * @Author:tongcao
 * @Date:2019/1/25 16:38
 * Description:
 */
@Data
public abstract class MessageHandle implements IMessageHandle {

    private String subExpression;


    /**
     * @param asyncMsg
     * @return
     */
    public abstract boolean consume(AsyncMsg asyncMsg);


}
